import pymysql

#连接数据库
def conn_db():
    #打开数据库连接
    db=pymysql.connect("localhost","root","","gwy",charset="utf8")
    return db

#获取数据库游标
def get_cursor(db):
    #使用cursor()方法创建一个游标对象cursor
    cursor=db.cursor()
    return cursor

#查询
def execute(cursor, sql):
    #使用execute()方法执行sql查询
    #cursor.execute("select version()")
    cursor.execute(sql)
    #使用fetchone()方法获取单条数据
    data=cursor.fetchone()
    return data

#关闭数据库连接
def close_db(db):
    #关闭数据库连接
    db.close()

